8d88d98952fcfee47bb8d450758499003e641483,providers/jms/src/java/org/mule/providers/jms/JmsMessageDispatcher.java,JmsMessageDispatcher,dispatchMessage,#UMOEvent#,65

Before Change


            String persistentDeliveryString = (String) event.removeProperty("PersistentDelivery");

            if (ttlString == null && priorityString == null && persistentDeliveryString == null) {
                connector.getJmsSupport().send(producer, msg);
            } else {
                long ttl = Message.DEFAULT_TIME_TO_LIVE;
                int priority = Message.DEFAULT_PRIORITY;

After Change


                persistent = Boolean.valueOf(persistentDeliveryString).booleanValue();
            }

            if (consumer != null && topic) {
                //need to register a listener for a topic
                Latch l = new Latch();
                ReplyToListener listener = new ReplyToListener(l);
                consumer.setMessageListener(listener);

                connector.getJmsSupport().send(producer, msg, persistent, priority, ttl);

                int timeout = event.getEndpoint().getRemoteSyncTimeout();
                logger.debug("Waiting for return event for: " + timeout + " ms on " + replyTo);